//package com.zj.sy.config.redis;
//
//import com.zj.sy.utils.JSONUtil;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.data.redis.core.RedisTemplate;
//import org.springframework.stereotype.Service;
//
//import java.util.Collection;
//
//
///**
//* @Description: 订阅消息发布器
//* @author Orange
//* @date 2019年4月15日
//*
//*/
//@Service
//public class RedisPublisher {
//	@Autowired
//	private RedisTemplate<String, String> redisTemplate;
//	@Autowired
//	private RedisService redisService;
//
//
//	/**
//	* @Title: sendMessage
//	* @Description: 发动默认主题订阅消息（缓存用）
//	* @param @param message    参数
//	* @return void    返回类型
//	* @throws
//	* @author Orange
//	* @date 2019年4月15日
//	*/
//	public void sendMessage(Object message) {
//		redisTemplate.convertAndSend(redisService.getTopic(), JSONUtil.toJSONString(message));
//	}
//
//
//	/**
//	* @Title: sendMessage
//	* @Description: 发布特定主题订阅消息
//	* @param @param redisPublisherTopicEnum
//	* @param @param message    参数
//	* @return void    返回类型
//	* @throws
//	* @author Orange
//	* @date 2019年4月15日
//	*/
//
//	public void sendMessage(RedisPublisherTopicEnum redisPublisherTopicEnum, Object message) {
//		redisTemplate.convertAndSend(redisPublisherTopicEnum.getTopic(),JSONUtil.toJSONString(message));
//	}
//
//
//	/**
//	* @Title: sendMessage
//	* @Description: 发布系列主题订阅消息
//	* @param @param topics
//	* @param @param message    参数
//	* @return void    返回类型
//	* @throws
//	* @author Orange
//	* @date 2019年4月15日
//	*/
//	public void sendMessage(Collection<String> topics, Object message) {
//		for(String topic:topics) {
//			redisTemplate.convertAndSend(topic,JSONUtil.toJSONString(message));
//		}
//	}
//
////	public static void main(String[] args) {
////		DataSyncPublisherVo dataSyncPublisherVo = new DataSyncPublisherVo();
////		dataSyncPublisherVo.setMessage("HAHA");
////		dataSyncPublisherVo.setDataSyncPublisherEnum(DataSyncPublisherEnum.COMPANY);
////		dataSyncPublisherVo.setRelationId(1);
////		String str = JSON.toJSONString(dataSyncPublisherVo);
////		System.out.println(JSON.toJSONString(dataSyncPublisherVo));
////
////		dataSyncPublisherVo = JSON.parseObject(str,DataSyncPublisherVo.class);
////		System.out.println("111");
////	}
//}
